package com.fly.push.flux.low;

import reactor.core.publisher.Flux;

public interface SsePublisherService
{
    Flux<String> getMessages();

    void publishMessage(String message);

    void complete();
}
